package com.spring.demo.config.async.http;

/**
 * 处理订单接口的任务，每个任务类处理一种接口
 *
 * @author xuweizhi
 */
//@Component
//@Slf4j
public class OrderTask /*extends Thread */ {

    //@Autowired
    //private RequestQueue queue;
    //
    //private boolean running = true;
    //
    //@Override
    //public void run() {
    //    while (running) {
    //        try {
    //            AsyncVo<String, Object> vo = queue.getOrderQueue().take();
    //            log.info("[ OrderTask ]开始处理订单");
    //
    //            String params = vo.getParams();
    //            Thread.sleep(3000);
    //            Map<String, Object> map = new HashMap<>(2);
    //            map.put("params", params);
    //            map.put("time", System.currentTimeMillis());
    //
    //            vo.getResult().setResult(map);
    //
    //            log.info("[ OrderTask ]订单处理完成");
    //        } catch (InterruptedException e) {
    //            e.printStackTrace();
    //            running = false;
    //        }
    //
    //    }
    //}
    //
    //public void setRunning(boolean running) {
    //    this.running = running;
    //}

}
